package com.example.folkmqdemo.consumer;

import org.noear.folkmq.client.MqConsumeHandler;
import org.noear.folkmq.client.MqMessageReceived;
import org.springframework.stereotype.Component;

import java.io.IOException;

@Component("event.user.updated")
public class EventUserUpdated implements MqConsumeHandler {
    @Override
    public void consume(MqMessageReceived message) throws IOException {
        System.out.println(message.getConsumerGroup()+":"+message.getBodyAsString());

    }
}
